//package com.lsc.admin.demo.mq;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//
///**
// * 消息监听消费
// *
// * @author ln
// */
//@EnableBinding(MqConSource.class)
//@Slf4j
//public class MqConsumer {
//
//    @StreamListener(MqConSource.MQ_INPUT)
//    public void onReceive(String shopJson) {
//        log.info(shopJson);
//    }
//}